968d86b53d4e6598757202cfcb27a7eef599c377,main/src/main/java/tachyon/worker/TachyonWorker.java,TachyonWorker,TachyonWorker,#InetSocketAddress#InetSocketAddress#number#number#number#number#String#number#,116
Before Change
// This is for Thrift 0.7.0, for Hive compatibility.
mServerTNonblockingServerSocket = new TNonblockingServerSocket(workerAddress);
mServer =
new THsHaServer(new THsHaServer.Args(mServerTNonblockingServerSocket).processor(
processor).workerThreads(workerThreads));
} catch (TTransportException e) {
LOG.error(e.getMessage(), e);
CommonUtils.runtimeException(e);
After Change
mServer =
new TThreadedSelectorServer(new TThreadedSelectorServer.Args(
new TNonblockingServerSocket(workerAddress)).processor(processor)
.selectorThreads(selectorThreads)
.acceptQueueSizePerThread(acceptQueueSizePerThreads).workerThreads(workerThreads));
} catch (TTransportException e) {
LOG.error(e.getMessage(), e);
CommonUtils.runtimeException(e);